package com.cci.kangdao.task;

import com.cci.kangdao.dao.ActivateIOSUserPhoneTokenTDao;
import com.cci.kangdao.dao.model.ActivateIOSUserPhoneTokenT;
import com.cci.kangdao.utilTool.LocalTimeUtil;
import javapns.devices.Device;
import javapns.devices.implementations.basic.BasicDevice;
import javapns.notification.AppleNotificationServerBasicImpl;
import javapns.notification.PushNotificationManager;
import javapns.notification.PushNotificationPayload;
import javapns.notification.PushedNotification;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

@Component
public class ActivateIOSTask {

	private Logger log = Logger.getLogger(this.getClass().getName());

	@Autowired
	private ActivateIOSUserPhoneTokenTDao activateIOSUserPhoneTokenTDao;

    public void activateIOS() {
		log.info("唤醒IOS服务定时任务已启动，当前时间为：" + LocalTimeUtil.getRealCurrentTime());
		//获取所有需要激活的IOS的手机token
		List<ActivateIOSUserPhoneTokenT> activateIOSUserPhoneTokenTs = activateIOSUserPhoneTokenTDao.getActivateIOSUserPhoneTokenTList();
		if(CollectionUtils.isNotEmpty(activateIOSUserPhoneTokenTs)) {
			for(ActivateIOSUserPhoneTokenT activateIOSUserPhoneTokenT : activateIOSUserPhoneTokenTs) {
				String deviceToken = activateIOSUserPhoneTokenT.getPhoneToken(); //绑定的手机token
		        String alert = "您有新消息!"; //push的内容
		        int badge = 1; //图标小红圈的数值
		        String sound = "default";//铃音
		     
		        List<String> tokens = new ArrayList<String>();
		        tokens.add(deviceToken);
		        String certificatePath = this.getClass().getResource("/voip.p12").getPath();  //获取证书相对路径
		        //String certificatePath = "D:/voip.p12";
		        String certificate = "";//此处注意导出的证书密码不能为空因为空密码会报错
		        boolean sendCount = true;	
		        try {
		            PushNotificationPayload payLoad = new PushNotificationPayload();
		            payLoad.addAlert(alert); // 消息内容
		            payLoad.addBadge(badge); // iphone应用图标上小红圈上的数值
		     
		            if (!StringUtils.isBlank(sound)) {
		                payLoad.addSound(sound);//铃音
		            }
		            PushNotificationManager pushManager = new PushNotificationManager();
		            //true：表示的是产品发布推送服务 false：表示的是产品测试推送服务
		            pushManager.initializeConnection(new AppleNotificationServerBasicImpl(certificatePath, certificate, true));
		            List<PushedNotification> notifications = new ArrayList<PushedNotification>();
		            // 发送push消息
		            if (sendCount) {
		                Device device = new BasicDevice();
		                device.setToken(tokens.get(0));
		                PushedNotification notification = pushManager.sendNotification(device, payLoad, true);
		                notifications.add(notification);
		            } else {
		                List<Device> device = new ArrayList<Device>();
		                for (String token : tokens) {
		                    device.add(new BasicDevice(token));
		                }
		                notifications = pushManager.sendNotifications(payLoad, device);
		            }
		            pushManager.stopConnection();
		        } catch (Exception e) {
		            e.printStackTrace();
		        } 
			}
		}
	}
}
